//package com.ybb.seckilldemo.config;
//
//import org.springframework.amqp.core.*;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//
///**
// * RabbitMQ配置类
// */
//
//@Configuration
//
//public class RabbitMQConfig {
//
//    private static final String QUEUE01 = "queue_fanout01";
//    private static final String QUEUE02 = "queue_fanout02";
//    private static final String EXCHANGE = "fanoutExchange";
//    private static final String QUEUE03 = "queue_direct03";
//    private static final String QUEUE04 = "queue_direct04";
//    private static final String EXCHANGE_DIRECT = "dirctExchange";
//    private static final String ROUTINGKET01 = "queue.red";
//    private static final String ROUTINGKET02 = "queue.green";
//
//
//    @Bean
//    public Queue queue() {
//        return new Queue("queue", true);
//    }
//
//    /**
//     * fanout模式
//     * @return
//     */
//    @Bean
//    public Queue queue01() {
//        return new Queue(QUEUE01);
//    }
//
//    @Bean
//    public Queue queue02() {
//        return new Queue(QUEUE02);
//    }
//
//    @Bean
//    public FanoutExchange fanoutExchange() {
//        return new FanoutExchange(EXCHANGE);
//    }
//
//    @Bean
//    public Binding binding01() {
//        return BindingBuilder.bind(queue01()).to(fanoutExchange());
//    }
//
//    @Bean
//    public Binding binding02() {
//        return BindingBuilder.bind(queue02()).to(fanoutExchange());
//    }
//
//    /**
//     * Direct 模式
//     */
//    @Bean
//    public Queue queue03() {
//        return new Queue(QUEUE03);
//    }
//
//    @Bean
//    public Queue queue04() {
//        return new Queue(QUEUE04);
//    }
//
//    @Bean
//    public DirectExchange directExchange() {
//        return new DirectExchange(EXCHANGE_DIRECT);
//    }
//
//    @Bean
//    public Binding binding03() {
//
//        return BindingBuilder.bind(queue03()).to(directExchange()).with(ROUTINGKET01);
//    }
//
//    @Bean
//    public Binding binding04() {
//        return BindingBuilder.bind(queue04()).to(directExchange()).with(ROUTINGKET02);
//    }
//}
